#ifndef THREADENVIADOR_H_
#define THREADENVIADOR_H_

#include "Thread.h"
#include "Conexion.h"
#include "Condition.h"
#include <queue>
#include <iostream>

using namespace std;

class InterfazPeer;

class ThreadEnviador: public Thread
{
private:
	Conexion *conexion;
	Condition *conditionCSalida;
	queue<string> *colaSalida;
	InterfazPeer* interfazPeer;

public:
	ThreadEnviador(InterfazPeer* interfazPeer, Conexion *conexion, Condition *conditionCSalida, queue<string> *colaSalida);
	virtual ~ThreadEnviador();
	virtual void* run();
	virtual void stop();

};

#endif /* COMMONTHREADENVIADOR_H_ */
